//package cn.dogger.easyboot.demo.controller;
//
//import cn.dogger.easyboot.kafka.utils.KafkaProducerUtils;
//import io.swagger.annotations.ApiOperation;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.util.concurrent.ExecutionException;
//import java.util.concurrent.TimeoutException;
//
///**
// * @author dogger
// * 2022/5/15 15:08
// */
//@RestController
//public class KafkaController {
//    private final Logger log;
//    private final KafkaProducerUtils<String,String> kafkaProducerUtils;
//
//    public KafkaController(KafkaProducerUtils<String, String> kafkaProducerUtils) {
//        log = LoggerFactory.getLogger(getClass());
//        this.kafkaProducerUtils = kafkaProducerUtils;
//    }
//
//
//    /**
//     * 同步单次发消息
//     * @throws ExecutionException 异常
//     * @throws InterruptedException 异常
//     * @throws TimeoutException 异常
//     */
//    @GetMapping("/3")
//    @ApiOperation("sendMessageSync")
//    public void sendMessageSync() throws ExecutionException, InterruptedException, TimeoutException {
//        kafkaProducerUtils.sendMessageSync("demo","1234444","同步发消息11");
//    }
//
//    /**
//     * 异步单次发消息
//     */
//    @GetMapping("/4")
//    @ApiOperation("sendMessageAsync")
//    public void sendMessageAsync() {
//        kafkaProducerUtils.sendMessageAsync("test","异步发送消息测试");
//    }
//
//    /**
//     * 同步单次接消息
//     * @param aaa 接收的参数
//     */
//    @KafkaListener(id = "1234444",topics = "demo")
//    public void acceptMessageSync(String aaa){
//        log.info("监听到了");
//        log.info(aaa);
//    }
//
//    /**
//     * 异步单次接消息
//     * @param aaa 接收的参数
//     */
//    @KafkaListener(topics = "test")
//    public void acceptMessageAsync(String aaa){
//        log.info("监听到了");
//        log.info(aaa);
//    }
//}
